package com.aiwiown.snackmq.api;

import com.aiwiown.snackmq.common.message.Message;

/**
 * 消息监听器接口
 * <p>
 * 业务方实现此接口来处理消费到的消息
 */
public interface MessageListener {
    /**
     * 消费消息
     * @param message 接收到的消息
     * @return 消费结果
     */
    ConsumeResult consume(Message message);
}